package com.yangchao.webflux.webserver;

import com.yangchao.webflux.vo.UserVO;
import org.springframework.http.MediaType;

import org.springframework.web.bind.annotation.RequestBody;

import org.springframework.web.service.annotation.HttpExchange;
import org.springframework.web.service.annotation.PostExchange;
import reactor.core.publisher.Flux;

@HttpExchange
public interface UserClient {

    @PostExchange(url = "/users", accept = MediaType.TEXT_EVENT_STREAM_VALUE)
    Flux<UserVO> getAll(@RequestBody UserVO userVO);
}